package org.zfes.snowier.xyz.analysis.queue;


public interface AnalyQueueBucket {

	static final String defaultTopic="t_";
	
	static final int batchSize=60;
	
	static final int SCHEDULED_QUEUE_LENGTH = 300;
	
	 static final int maxOfferThreads=6;
	 static final int maxOfferThreadQueueSize=1024*1024;
	
	void offer(Object msg);
	
	void clear();
	
	
}
